package service

import (
	"github.com/crack007/go-im/src/common"
	"github.com/crack007/go-im/src/common/config"
	"github.com/crack007/go-im/src/common/model"
)

var ConsumerService *consumerService

func RegisterConsumerService() {
	common.Bootstrap()
	ConsumerService = &consumerService{
		msgQueue: make(chan *model.MessageModel, config.MsgConfig.DbQueueSize),
	}
}
